package com.lcy.chat;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;


public class ChatReceiver extends Thread  {
	
	Socket socket;
	
	public ChatReceiver( Socket socket )
	{
		//host, port 형식의 Client Receiver 소켓을 생성
		this.socket = socket;
	}
	public void run()
	{
		try
		{
			//소켓에서 오는 Inputstream정보를 받는다
			BufferedReader reader = new BufferedReader( new InputStreamReader( socket.getInputStream() ) );
			while( true )
			{	
				//쓰레드가 살아있는동안 계속해서 소켓에서 오는 InputStream정보를 읽어온다. (한줄씩 데이타를 읽어옴 )
				String str = reader.readLine();
				if( str == null )
				{
					break;
				}
				System.out.println(str);
			}
		}
		catch (IOException e)
		{
			System.out.println( e.getMessage() );
		}
	}
}
